package com.spark.sql

import org.apache.spark.SparkConf
import org.apache.spark.sql._

/**
  *
  * @author Pop
  * @date 2022/7/20 22:48
  */
object Spark06_SparkSql_Hive {
  def main(args: Array[String]): Unit = {

    // 创建SparkSql的运行环境
    val sparkSql: SparkConf = new SparkConf().setMaster("local[*]").setAppName("sparkSql")
    val session: SparkSession = SparkSession.builder()
      .enableHiveSupport()//启动hive支持，很重要
      .config(sparkSql).getOrCreate()

    // 使用SparkSql连接外置的hive
    // 1.拷贝hive-site.xml文件拷贝到classpath下
    // 2.启动Hive的支持
    // 3.增加对应的依赖关系(包含mysql的驱动)
    session.sql("show tables").show
    //如果这里展示，和spark spark-shell 一样的就表示连接外部ok



    session.close()
  }

}
